package com.kedacom.demo.spring.websocket.rpc;

import java.util.concurrent.LinkedBlockingQueue;

public class PendingRequest {

	private volatile String requestId;
	private final LinkedBlockingQueue<String> queue;

	public PendingRequest(String requestId) {
		this.setRequestId(requestId);
		this.queue = new LinkedBlockingQueue<String>();
	}

	public String getRequestId() {
		return requestId;
	}

	public void setRequestId(String requestId) {
		this.requestId = requestId;
	}

	public LinkedBlockingQueue<String> getQueue() {
		return queue;
	}

}
